package com.bnz.user.config;

import org.apache.rocketmq.client.producer.DefaultMQProducer;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class RocketMQProducerConfig {

	@Bean
	public DefaultMQProducer defaultMQProducer(){
		DefaultMQProducer defaultMQProducer = new DefaultMQProducer();
		defaultMQProducer.setNamesrvAddr("192.168.151.151:9876");
		defaultMQProducer.setProducerGroup("producer-01");
		return defaultMQProducer;
	}
}